package com.vip.kafka.service;

import com.vip.kafka.response.Result;

import java.util.List;

/**
 * description
 *
 * @author wgb
 * @date 2020/5/19 15:52
 */
public interface IKafkaService {
    /**
     * 创建主题
     *
     * @param topic
     * @return
     */
    Result<String> createTopic(String topic);

    /**
     * 推送消息
     *
     * @param topic
     * @param message
     * @return
     */
    Result<String> sendMessage(String topic, String message);

    /**
     * 删除主题
     *
     * @param topic
     * @return
     */
    Result<String> deleteTopic(String topic);

    /**
     * 主题列表
     *
     * @return
     */
    Result<List<String>> topicList();
}
